package com.pw.study.flink.function

import com.pw.study.flink.entities.WordBeanOne
import org.apache.flink.api.common.functions.MapFunction

class CustomMapFunction extends MapFunction[String,WordBeanOne]{
  override def map(t: String): WordBeanOne = {
    WordBeanOne(t,1L)
  }
}
